CreateNotificationCommandHandler.execute - Code Metrics - Inspection of "Merge pull request #436 from fairnesscoop/feat-mm-..." - fairnesscoop/permacoop - Measure and Improve Code Quality continuously with Scrutinizer

Passed

Push — master ( 26b471...d6088a )

by Mathieu

created 2024-06-28 09:18 UTC

CreateNotificationCommandHandler.execute B

↳ Parent: CreateNotificationCommandHandler

Complexity

Conditions

Size

Total Lines	57
Code Lines	45

Duplication

Lines	0
Ratio	0 %

Importance

Changes

Metric	Value
eloc	45
dl	0
loc	57
rs	8.8
c	0
b	0
f	0
cc	4

How to fix Long Method

import { Inject } from '@nestjs/common';
import { CommandHandler } from '@nestjs/cqrs';
import {
  Notification,
  NotificationType
} from 'src/Domain/Notification/Notification.entity';
import { CreateNotificationCommand } from './CreateNotificationCommand';
import { INotificationRepository } from 'src/Domain/Notification/Repository/INotificationRepository';
import { IMattermostNotifier } from 'src/Application/IMattermostNotifier';
import { ConfigService } from '@nestjs/config';

const { MATTERMOST_CHANNEL_LEAVES_ID } = process.env;

@CommandHandler(CreateNotificationCommand)
export class CreateNotificationCommandHandler {
  constructor(
    @Inject('INotificationRepository')
    private readonly notificationRepository: INotificationRepository,
    @Inject('IMattermostNotifier')
    private readonly mattermostNotifier: IMattermostNotifier,
    private readonly configService: ConfigService
  ) {}

  public async execute(command: CreateNotificationCommand): Promise<string> {
    const { message, type, leaveReaquest } = command;

    if (type === NotificationType.POST) {
      const { id } = await this.mattermostNotifier.createPost(
        MATTERMOST_CHANNEL_LEAVES_ID,
        message
      );
      const notification = await this.notificationRepository.save(
        new Notification(type, message, id, leaveReaquest)
      );

      return notification.getId();
    }

    if (type === NotificationType.REACTION) {
      const rootNotification = await this.getRootNotification(
        leaveReaquest.getId()
      );

      await this.mattermostNotifier.createReaction(
        rootNotification.getResourceId(),
        message
      );

      const notification = await this.notificationRepository.save(
        new Notification(
          type,
          message,
          rootNotification.getResourceId(),
          leaveReaquest
        )
      );

      return notification.getId();
    }

    if (type === NotificationType.COMMENT) {
      const rootNotification = await this.getRootNotification(
        leaveReaquest.getId()
      );

      const { id } = await this.mattermostNotifier.createComment(
        this.configService.get<string>('MATTERMOST_CHANNEL_LEAVES_ID'),
        message,
        rootNotification.getResourceId()
      );

      const notification = await this.notificationRepository.save(
        new Notification(type, message, id, leaveReaquest)
      );

      return notification.getId();
    }

    throw new Error('Type not managed');
  }

  private async getRootNotification(leaveReaquestId: string) {
    return await this.notificationRepository.findByLeaveRequestIdAndType(
      leaveReaquestId,
      NotificationType.POST
    );
  }
}


1			import { Inject } from '@nestjs/common';
2			import { CommandHandler } from '@nestjs/cqrs';
3			import {
4			Notification,
5			NotificationType
6			} from 'src/Domain/Notification/Notification.entity';
7			import { CreateNotificationCommand } from './CreateNotificationCommand';
8			import { INotificationRepository } from 'src/Domain/Notification/Repository/INotificationRepository';
9			import { IMattermostNotifier } from 'src/Application/IMattermostNotifier';
10			import { ConfigService } from '@nestjs/config';
11
12			const { MATTERMOST_CHANNEL_LEAVES_ID } = process.env;
13
14			@CommandHandler(CreateNotificationCommand)
15			export class CreateNotificationCommandHandler {
16			constructor(
17			@Inject('INotificationRepository')
18			private readonly notificationRepository: INotificationRepository,
19			@Inject('IMattermostNotifier')
20			private readonly mattermostNotifier: IMattermostNotifier,
21			private readonly configService: ConfigService
22			) {}
23
24			public async execute(command: CreateNotificationCommand): Promise<string> {
25			const { message, type, leaveReaquest } = command;
26
27			if (type === NotificationType.POST) {
28			const { id } = await this.mattermostNotifier.createPost(
29			MATTERMOST_CHANNEL_LEAVES_ID,
30			message
31			);
32			const notification = await this.notificationRepository.save(
33			new Notification(type, message, id, leaveReaquest)
34			);
35
36			return notification.getId();
37			}
38
39			if (type === NotificationType.REACTION) {
40			const rootNotification = await this.getRootNotification(
41			leaveReaquest.getId()
42			);
43
44			await this.mattermostNotifier.createReaction(
45			rootNotification.getResourceId(),
46			message
47			);
48
49			const notification = await this.notificationRepository.save(
50			new Notification(
51			type,
52			message,
53			rootNotification.getResourceId(),
54			leaveReaquest
55			)
56			);
57
58			return notification.getId();
59			}
60
61			if (type === NotificationType.COMMENT) {
62			const rootNotification = await this.getRootNotification(
63			leaveReaquest.getId()
64			);
65
66			const { id } = await this.mattermostNotifier.createComment(
67			this.configService.get<string>('MATTERMOST_CHANNEL_LEAVES_ID'),
68			message,
69			rootNotification.getResourceId()
70			);
71
72			const notification = await this.notificationRepository.save(
73			new Notification(type, message, id, leaveReaquest)
74			);
75
76			return notification.getId();
77			}
78
79			throw new Error('Type not managed');
80			}
81
82			private async getRootNotification(leaveReaquestId: string) {
83			return await this.notificationRepository.findByLeaveRequestIdAndType(
84			leaveReaquestId,
85			NotificationType.POST
86			);
87			}
88			}
89

fairnesscoop / permacoop

Push — master ( 26b471...d6088a )

CreateNotificationCommandHandler.execute B

Complexity

Size

Duplication

Importance

How to fix Long Method

Long Method

Duplication Side-by-Side

Filter issues like